package com.abyss.source;

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.operators.DataSource;

/**
 * @author Abyss
 * @date 2020/10/4
 * @description 从gz压缩文件中读取内容
 */

public class CompressFileSourceDemo {
    public static void main(String[] args) throws Exception {
        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
        DataSource<String> gzSource = env.readTextFile("file:/Users/abyss/Dev/toys/flink/H-flink-learn/target/classes/test.gz");
        gzSource.print();
    }
}
